4be4ed0b280d92aacf1a30b88008258884a14301,src/main/java/org/springframework/data/redis/connection/lettuce/LettuceConnection.java,LettuceConnection,pfAdd,#number[]#number[]#,4359
Before Change
try {
if (isPipelined()) {
if (values.length == 1) {
pipeline(new LettuceResult(getAsyncConnection().pfadd(key, values[0])));
} else {
pipeline(
new LettuceResult(getAsyncConnection().pfadd(key, values[0], LettuceConverters.subarray(values, 1))));
}
return null;
}
if (isQueueing()) {
if (values.length == 1) {
transaction(new LettuceTxResult(getConnection().pfadd(key, values[0])));
} else {
transaction(
new LettuceTxResult(getConnection().pfadd(key, values[0], LettuceConverters.subarray(values, 1))));
}
return null;
}
if (values.length == 1) {
return getConnection().pfadd(key, values[0]);
}
return getConnection().pfadd(key, values[0], LettuceConverters.subarray(values, 1));
} catch (Exception ex) {
throw convertLettuceAccessException(ex);
}
After Change
* @see org.springframework.data.redis.connection.HyperLogLogCommands#pfAdd(byte[], byte[][])
*/
@Override
public Long pfAdd(byte[] key, byte[]... values) {
Assert.notEmpty(values, "PFADD requires at least one non 'null' value.");
Assert.noNullElements(values, "Values for PFADD must not contain 'null'.");
try {
if (isPipelined()) {
RedisHLLAsyncCommands<byte[], byte[]> asyncConnection = getAsyncConnection();
pipeline(new LettuceResult(asyncConnection.pfadd(key, values)));
return null;
}